const express = require('express');
const bodyParser = require('body-parser');
const mysql = require('mysql');
const app = express();

// 解析POST请求主体
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));

// 创建MySQL连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: '19588557923',
  database: 'smallroute'
});

// 连接MySQL数据库
connection.connect((err) => {
  if (err) {
    console.error('失败：' + err.stack);
    return;
  }
  console.log('成功');
});

// 定义路由
app.get('/api', (req, res) => {
  // 查询示例：获取所有数据
  const query = 'SELECT * FROM carouselchart';
  connection.query(query, (err, results) => {
    if (err) {
      console.error('成功: ' + err.stack);
      return;
    }
    res.send(results);
    console.log(results)
  });
});

// 定义路由
app.get('/NavigationData', (req, res) => {
  // 查询示例：获取所有数据
  const query = 'SELECT * FROM navigationdata';
  connection.query(query, (err, results) => {
    if (err) {
      console.error('成功: ' + err.stack);
      return;
    }
    res.send(results);
    console.log(results)
  });
});

app.get('/floortitle', (req, res) => {
  // 查询示例：获取所有数据
  const query = 'SELECT * FROM floortitle';
  connection.query(query, (err, results) => {
    if (err) {
      console.error('成功: ' + err.stack);
      return;
    }
    res.send(results);
    console.log(results)
  });
});

app.get('/productlist', (req, res) => {
  // 查询示例：获取所有数据
  const query = 'SELECT * FROM productlist';
  connection.query(query, (err, results) => {
    if (err) {
      console.error('成功: ' + err.stack);
      return;
    }
    res.send(results);
    console.log(results)
  });
});

app.get('/catelist', (req, res) => { 
  // 查询示例：获取所有数据
  const query = 'SELECT * FROM catelist';
  connection.query(query, (err, results) => {
    if (err) {
      console.error('成功: ' + err.stack);
      return;
    }
    res.send(results);
    console.log(results)
  });
});

// 查询指定数据

app.post('/children', (req, res) => {
  // 获取POST参数
  const param1 = req.body.param1;
  // console.log(param1)

   // 执行查询语句
   connection.query('SELECT * FROM children WHERE cat_id = ?', [param1], (err, results) => {
    if (err) {
      console.error('Error executing query:', err);
      res.status(500).send('Error executing query');
      return;
    }

    // 将查询结果返回给客户端
    res.json(results);
    console.log(results)
  });
});

// 添加数据

app.post('/add', (req, res) => {
  // 获取POST参数
  const param1 = req.body.param1;
  const param2 = req.body.param2;
  console.log(param1)

  // 执行插入操作
  connection.query('INSERT INTO login (id,name) VALUES (?, ?)', [param1,param2], (err, results) => {
    if (err) {
     console.error('Error executing query:', err);
     return;
    }
    console.log('Data inserted successfully:', results);
  });

    // 将查询结果返回给客户端
    res.json(results);
    console.log(results)
});

app.get('/login', (req, res) => {
  // 查询示例：获取所有数据
  const query = 'SELECT * FROM login';
  connection.query(query, (err, results) => {
    if (err) {
      console.error('成功: ' + err.stack);
      return;
    }
    res.send(results);
    console.log(results)
  });
});

// 删除操作

app.post('/dele', (req, res) => {
  // 获取POST参数
  const param1 = req.body.param1;
  // const param2 = req.body.param2;
  // console.log(param1)

  // 执行插入操作
  connection.query('DELETE FROM login WHERE id = ?', [param1], (err, results) => {
    if (err) {
     console.error('Error executing query:', err);
     return;
    }
    console.log('Data inserted successfully:', results);
  });

    // 将查询结果返回给客户端
    res.json(results);
    console.log(results)
});



// 更改数据

// const sql = 'INSERT INTO tab_sus (id, name,xb,df) VALUES (6,"吕布","男","三国")';
// const values = ['6', '吕布',"男","三国"];
// connection.query(sql, values, (err, results, fields) => {
  // if (err) {
    // console.error('error running query: ' + err.stack);
    // return;
  // }
  // console.log('insertId: ' + results.insertId);
// });

// 启动服务器

app.listen(3000, () => {
  console.log('服务器已启动，监听端口3000');
});